/**
 * 检查点
 *
 * @author huangchao E-mail:fengquan8866@163.com
 * @version 创建时间：2024/9/30 21:44
 */
package com.at.checkpoint15;
/**
 * TODO 检查点算法的总结
 * 1、Barrier对齐： 一个 Task 收到 所有上游 同一个编号的 Barrier 之后，才会对自己的本地状态做 备份
 *      精准一次： 在Barrier对齐过程中，Barrier后面的数据 阻塞等待（不会越过Barrier）
 *      至少一次： 在Barrier对齐过程中，先到的Barrier，其后面的数据 不阻塞 接着计算
 *
 *
 * 2、非Barrier对齐： 一个Task 收到 第一个 Barrier 时，就开始 执行备份，能保证 精准一次（flink 1.11出的新算法）
 *      先到的Barrier，将 本地状态 备份，其后面的数据接着计算输出
 *      未到的Barrier，其 前面的数据 接着计算输出，同时 也保存到 备份中
 *      最后一个Barrier到达 该Task时，这个Task的备份结束
 */